package zhongbo.java.air.monitor.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import zhongbo.java.air.monitor.web.websocket.AlertZoneWebSocket;

@Component
@Service
@Slf4j
public class RedisLogChanelPublisher {
//    // 制作 将发布消息存入redis 的方法 供业务层引用
//    @Autowired
//    private RedisTemplate<String, String> redisTemplate; // 使用配置好的JSON序列化模板
//
//    /**
//     * 发布消息到指定频道
//     * @param channel 频道名称（如 RedisConfig.CHAT_CHANNEL 或 RedisListenerConfig.LOG_CHANEL）
//     * @param message 消息内容（自动被JSON序列化）
//     */
//    public void pubDoSomethingMessage(String channel, String message) {
//        redisTemplate.convertAndSend(channel, message);
//    }

    @Autowired
    private StringRedisTemplate redisTemplate;



    public void publish(String channel, Object message) {
        log.info("\n准备发布消息到频道: " + channel);
        if ("alert_zone_chanel".equals(channel)) {

        }

    }

}
